package cm.tl.pms.util.redis;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

/**
 * redis队列
 *
 * @author w7h1te_ywq
 * @version 1.0.0
 * @date 2024-01-17 13:36
 */
@Component
public class RedisMessageQueue {

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    /**
     * 向消息队列发送消息
     *
     * @param queueName 队列名称
     * @param message   消息内容
     */
    public void sendMessage(String queueName, String message) {//将消息添加到指定队列的左侧
        redisTemplate.opsForList().leftPush(queueName, message);
    }

    /**
     * 从消息队列接收消息
     *
     * @param queueName 队列名称
     * @return 接收到的消息
     */
    public String receiveMessage(String queueName) {//从指定队列的右侧弹出消息
        return redisTemplate.opsForList().rightPop(queueName);
    }


}